package com.qf.flinketl.flinkconfig.configImpl;

import com.qf.flinketl.flinkconfig.ProxyType;
import lombok.Data;
import org.springframework.beans.factory.annotation.Value;

/**
 * @Description: @Author: KyrieFc @Date: 2023/10/24
 */
@Data
public class KafkaSourceConfigImpl {
  private ProxyType proxyType;
  private String serviceName;
  private int sourceParallelism;
  private String dataName;
  private boolean useRawData;
  private boolean needParsed;
  private boolean needFiltered;
  private String sourceTopic;
  private String consumerId;
  private String sourceType;
  private String dropDataKey;
  private String downGradeKey;
}
